package org.apache.flink

import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

object BasicApp1 {

    def main(args: Array[String]): Unit = {

        val env: StreamExecutionEnvironment = StreamExecutionEnvironment.getExecutionEnvironment

        env.fromElements(List(1,2,3,4,5)).print()

        env.execute("app2")
    }
}
